package com.ow.dva.module.base.service;

public interface KafkaService {

    /**
     * 发送消息到 "dva-client" topic
     * @param message 消息体
     */
    void sendMessage(Object message);

    /**
     * 发送消息到指定topic
     * @param topic 指定topic名称
     * @param message 消息体
     */
    void sendMessage(String topic, Object message);

    /**
     * 发送信息
     * @param type 1-单条发送过车记录，2-单条发送订单信息
     * @param topic
     * @param message
     */
    void sendMessage(Integer type,String topic, Object message);
}
